package com.hqyj.bigdata_project.util;

public class ETLUtil {

    /**
     * 1.过滤掉长度不够的，小于9个字段
     * 2.去掉类别字段中的空格
     * 3.修改相关视频ID字段的分隔符，‘\t’替换为'&'
     * @param oriStr
     * @return
     */

    public static String etlStr(String oriStr){

        StringBuffer sb = new StringBuffer();

        //1.切割
        String[] fields = oriStr.split("\t");

        //第一个把一些非法的视频资料清洗掉。
        //2.对字段长度进行过滤（我们一共有10个字段）
        if (fields.length<9){
            return null;
        }else {
            try {
                int temp = Integer.parseInt(fields[8]);
            }catch (NumberFormatException ex){
                ex.printStackTrace();
                System.out.println("缺失重要字段....");
                return null;
            }
        }

        //3.去掉类别字段的空格
        fields[3] = fields[3].replaceAll(" ","");


        //4.修改相关视频ID字段的分隔符，由‘t’替换为‘&’
        for (int i = 0; i < fields.length; i++) {

            //对非相关ID进行处理
            if (i < 9) {
                sb.append(fields[i]).append("\t");
            } else {
                //对非相关ID字段进行处理  第一个是输出结尾的值tsSmTN3h_9-s
                if (i == fields.length - 1) {
                    sb.append(fields[i]);
                } else {
                    sb.append(fields[i]).append("&");
                }
            }
        }
        //5.返回结果
        return sb.toString();
    }

    /*
    public static void main(String[] args) {
        System.out.println(ETLUtil.etlStr("bdDskrr8jRY\tjana9999\t589\tPeople & Blogs\t219\t414\t1" +
                ".73\t15\t14\t7D0Mf4Kn4Xk\tbdDskrr8jRY\tORbIqKM-Wkc\tj2uwoUGbRY8\tTeGGfjqQASk\tyuO6yjlvXe8" +
                "\tXCpe8Z5bi74\tG0KPorRyxzA\tBfmbPtL0iMg\txd1BK7eHtmE\tII6sc3fWMmw\te2k0h6tPvGc\ty3IDp2n7B48" +
                "\th944I8xXmqc\t60f6z_DWhBs\tk7_fEazJQpA\tXKI2J8ecimk\t_NwCteJyUPg\ttBUsm2RbkV4\tsSmTN3h_9-s"));
    }*/
}
